home *** CD-ROM | disk | FTP | other *** search
/ AmigActive 25 / AACD 25.iso / AACD / Magazine / Online / QMail / source / qmail-smtpd.c < prev    next >
Encoding:
C/C++ Source or Header  |  1997-10-02  |  17.9 KB  |  726 lines
  1. #define BADRCPT 1
  2. #define SYSLOGGING 1
  3. #define DENYSPAM 1
  4. #define MAILFROMCHECK 1
  5. #define MAILFROMDNS 1
  6. /*zzz Version 0.9r1.0*/
  7. #include "sig.h"
  8. #include "readwrite.h"
  9. #include "getln.h"
  10. #include "stralloc.h"
  11. #include "substdio.h"
  12. #ifdef SYSLOGGING
  13. #ifdef __amigaos__ /* Work around syslog.h bug.  */
  14. #include <machine/ansi.h>
  15. #endif
  16. #include <syslog.h>
  17. #endif
  18. #include "alloc.h"
  19. #include "auto_qmail.h"
  20. #include "control.h"
  21. #include "received.h"
  22. #include "constmap.h"
  23. #include "error.h"
  24. #include "ipme.h"
  25. #include "ip.h"
  26. #include "qmail.h"
  27. #include "str.h"
  28. #include "fmt.h"
  29. #include "byte.h"
  30. #include "case.h"
  31. #include "env.h"
  32. #include "now.h"
  33. #include "exit.h"
  34. #ifdef MAILFROMDNS
  35. #include "dns.h"
  36. #endif
  37.  
  38. #define MAXHOPS 100
  39. int timeout = 1200;
  40.  
  41. char ssoutbuf[512];
  42. substdio ssout = SUBSTDIO_FDBUF(write,1,ssoutbuf,sizeof(ssoutbuf));
  43.  
  44. void die() { substdio_flush(&ssout); closelog (); _exit(1); }
  45. void flush() { if (substdio_flush(&ssout) == -1) { closelog (); _exit(1); } }
  46. void out(s) char *s; { if (substdio_puts(&ssout,s) == -1) die(); }
  47.  
  48. int timeoutread(fd,buf,n) int fd; char *buf; int n;
  49. {
  50.  int r; int saveerrno;
  51.  flush();
  52.  alarm(timeout);
  53.  r = read(fd,buf,n); saveerrno = errno;
  54.  alarm(0);
  55.  errno = saveerrno; return r;
  56. }
  57.  
  58. char ssinbuf[1024];
  59. substdio ssin = SUBSTDIO_FDBUF(timeoutread,0,ssinbuf,sizeof(ssinbuf));
  60.  
  61.  
  62. struct qmail qqt;
  63. stralloc greeting = {0};
  64. int liphostok = 0;
  65. stralloc liphost = {0};
  66. int rhok = 0;
  67. stralloc rcpthosts = {0};
  68. struct constmap maprcpthosts;
  69. int bmfok = 0;
  70. stralloc bmf = {0};
  71. struct constmap mapbmf;
  72. int flagbarf; /* defined if seenmail */
  73. #ifdef BADRCPT
  74. int brtok = 0;
  75. stralloc brt = {0};
  76. struct constmap mapbadrcptto;
  77. #endif
  78.  
  79. stralloc helohost = {0};
  80. stralloc mailfrom = {0};
  81. stralloc rcptto = {0};
  82. stralloc relayclients = {0};
  83. stralloc relaydomains = {0};
  84. struct constmap maprelayclients, maprelaydomains;
  85. int seenmail = 0;
  86.  
  87. stralloc addr = {0}; /* will be 0-terminated, if addrparse returns 1 */
  88.  
  89. char *remoteip;
  90. char *remotehost;
  91. char *remoteinfo;
  92. char *local;
  93. char *relayclient;
  94. #ifdef DENYSPAM
  95. char *denymail;
  96. #endif
  97.  
  98. void outofmem()
  99. {
  100. #ifdef SYSLOGGING
  101.   syslog (LOG_ERR, "Out of memory while connected to %s!\n", remoteip);
  102. #endif
  103.   out("421 out of memory (#4.3.0)\r\n"); die();
  104. }
  105.  
  106. void sigalrm()
  107. {
  108. #ifdef SYSLOGGING
  109.   syslog (LOG_INFO, "Connection to %s timed out.\n", remoteip);
  110. #endif
  111.   out("451 timeout (#4.4.2)\r\n"); die();
  112. }
  113.  
  114. void dohelo(arg) char *arg;
  115. {
  116.  if (!stralloc_copys(&helohost,arg)) outofmem(); 
  117.  if (!stralloc_0(&helohost)) outofmem(); 
  118. }
  119.  
  120. void getenvs()
  121. {
  122.  unsigned short int error = 0;
  123.  unsigned int i, len;
  124.  
  125.  remoteip = env_get("TCPREMOTEIP");
  126.  if (!remoteip) remoteip = "unknown";
  127.  local = env_get("TCPLOCALHOST");
  128.  if (!local) local = env_get("TCPLOCALIP");
  129.  if (!local) local = "unknown";
  130.  remotehost = env_get("TCPREMOTEHOST");
  131.  if (!remotehost) remotehost = "unknown";
  132.  remoteinfo = env_get("TCPREMOTEINFO");
  133.  relayclient = env_get("RELAYCLIENT");
  134.  if (! relayclient)
  135.  {
  136.    /* Attempt to look up the IP number in control/relayclients. */
  137.    switch (control_readfile (&relayclients, "control/relayclients", 0))
  138.    {
  139.      case -1:
  140.      if (errno == error_nomem)
  141.        outofmem ();
  142.      /* Fall through. */
  143.  
  144.      case 0:
  145.      error = 1;
  146.      break;
  147.  
  148.      case 1:
  149.      if (!constmap_init (&maprelayclients, relayclients.s, relayclients.len, 1))
  150.        outofmem ();
  151.      break;
  152.    }
  153.  
  154.   if (! error)
  155.   {
  156.     for (i = len = str_len (remoteip); i > 0; i --)
  157.       if ((i == len) || (remoteip[i - 1] == '.'))
  158.         if ((relayclient = constmap (&maprelayclients, remoteip, i)))
  159.           break;
  160.   }
  161.  }
  162.  
  163.  error = 0;
  164.  if (! relayclient)
  165.  {
  166.    /* Attempt to look up the host name in control/relaydomains. */
  167.    switch (control_readfile (&relaydomains, "control/relaydomains", 0))
  168.    {
  169.      case -1:
  170.      if (errno == error_nomem)
  171.        outofmem ();
  172.      /* Fall through. */
  173.  
  174.      case 0:
  175.      error = 1;
  176.      break;
  177.  
  178.      case 1:
  179.      if (!constmap_init (&maprelaydomains, relaydomains.s, relaydomains.len, 1))
  180.        outofmem ();
  181.      break;
  182.    }
  183.  
  184.   if (! error)
  185.   {
  186.     for (i = 0, len = str_len (remotehost); i <= len; i ++)
  187.       if ((i == 0) || (i == len) || (remotehost[i] == '.'))
  188.         if ((relayclient = constmap (&maprelaydomains, remotehost + i, len - i)))
  189.           break;
  190.   }
  191.  }
  192.  
  193.  dohelo(remotehost);
  194. #ifdef DENYSPAM
  195.  denymail = env_get("DENYMAIL");
  196. #endif
  197. }
  198.  
  199. void blast(ssfrom,hops)
  200. substdio *ssfrom;
  201. int *hops;
  202. {
  203.  char ch;
  204.  int state;
  205.  int flaginheader;
  206.  int pos; /* number of bytes since most recent \n, if fih */
  207.  int flagmaybex; /* 1 if this line might match RECEIVED, if fih */
  208.  int flagmaybey; /* 1 if this line might match \r\n, if fih */
  209.  int flagmaybez; /* 1 if this line might match DELIVERED, if fih */
  210.  
  211.  state = 1;
  212.  *hops = 0;
  213.  flaginheader = 1;
  214.  pos = 0; flagmaybex = flagmaybey = flagmaybez = 1;
  215.  for (;;)
  216.   {
  217.    if (substdio_get(ssfrom,&ch,1) <= 0) die();
  218.    if (flaginheader)
  219.     {
  220.      if (pos < 9)
  221.       {
  222.        if (ch != "delivered"[pos]) if (ch != "DELIVERED"[pos]) flagmaybez = 0;
  223.        if (flagmaybez) if (pos == 8) ++*hops;
  224.        if (pos < 8)
  225.          if (ch != "received"[pos]) if (ch != "RECEIVED"[pos]) flagmaybex = 0;
  226.        if (flagmaybex) if (pos == 7) ++*hops;
  227.        if (pos < 2) if (ch != "\r\n"[pos]) flagmaybey = 0;
  228.        if (flagmaybey) if (pos == 1) flaginheader = 0;
  229.       }
  230.      ++pos;
  231.      if (ch == '\n') { pos = 0; flagmaybex = flagmaybey = flagmaybez = 1; }
  232.     }
  233.    switch(state)
  234.     {
  235.      case 0:
  236.        if (ch == '\r') { state = 4; continue; }
  237.        break;
  238.      case 1: /* \r\n */
  239.        if (ch == '.') { state = 2; continue; }
  240.        if (ch == '\r') { state = 4; continue; }
  241.        state = 0;
  242.        break;
  243.      case 2: /* \r\n + . */
  244.        if (ch == '\r') { state = 3; continue; }
  245.        state = 0;
  246.        break;
  247.      case 3: /* \r\n + .\r */
  248.        if (ch == '\n') return;
  249.        qmail_put(&qqt,".\r",2);
  250.        if (ch == '\r') { state = 4; continue; }
  251.        state = 0;
  252.        break;
  253.      case 4: /* + \r */
  254.        if (ch == '\n') { state = 1; break; }
  255.        if (ch != '\r') { qmail_put(&qqt,"\r",1); state = 0; }
  256.     }
  257.    qmail_put(&qqt,&ch,1);
  258.   }
  259. }
  260.  
  261. int addrparse(arg)
  262. char *arg;
  263. {
  264.  int i;
  265.  char ch;
  266.  struct ip_address ip;
  267.  int flagesc;
  268.  int flagquoted;
  269.  
  270.  arg += str_chr(arg,'<');
  271.  if (*arg != '<') return 0;
  272.  ++arg;
  273.  
  274.  /* strip source route */
  275.  if (*arg == '@') while (*arg) if (*arg++ == ':') break;
  276.  
  277.  if (!*arg) return 0;
  278.  if (!stralloc_copys(&addr,"")) outofmem();
  279.  flagesc = 0;
  280.  flagquoted = 0;
  281.  for (i = 0;ch = arg[i];++i) /* copy arg to addr, stripping quotes */
  282.   {
  283.    if (flagesc)
  284.     { if (!stralloc_append(&addr,&ch)) outofmem(); flagesc = 0; }
  285.    else
  286.     {
  287.      if (!flagquoted && (ch == '>')) break;
  288.      switch(ch)
  289.       {
  290.        case '\\': flagesc = 1; break;
  291.        case '"': flagquoted = !flagquoted; break;
  292.        default: if (!stralloc_append(&addr,&ch)) outofmem();
  293.       }
  294.     }
  295.   }
  296.  if (!ch) return 0;
  297.  if (!stralloc_append(&addr,"")) outofmem();
  298.  ++i;
  299.  while (arg[i])
  300.   {
  301.    if (!case_diffs(arg + i," BODY=8BITMIME")) i += 14;
  302.    else if (!case_diffs(arg + i," BODY=7BIT")) i += 10;
  303.    else return 0;
  304.   }
  305.  
  306.  if (liphostok)
  307.   {
  308.    i = byte_rchr(addr.s,addr.len,'@');
  309.    if (i < addr.len) /* if not, partner should go read rfc 821 */
  310.      if (addr.s[i + 1] == '[')
  311.        if (!addr.s[i + 1 + ip_scanbracket(addr.s + i + 1,&ip)])
  312.          if (ipme_is(&ip))
  313.           {
  314.            addr.len = i + 1;
  315.            if (!stralloc_cat(&addr,&liphost)) outofmem();
  316.            if (!stralloc_0(&addr)) outofmem();
  317.           }
  318.   }
  319.  
  320.  return 1;
  321. }
  322.  
  323. #ifdef SYSLOGGING
  324.  
  325. static void log_deny(m,f,t) char *m,*f,*t;
  326. {
  327.   syslog (LOG_INFO, "%s check failed (%s) -> (%s) [%s] (HELO %s)",
  328.           m, f, t, remoteip, helohost.s);
  329. } 
  330.  
  331. #ifdef BADRCPT
  332. static void log_brt(s,r) char *s,*r;
  333. {
  334.   log_deny("Bad RCPT TO:", s, r);
  335. } 
  336. #endif
  337.  
  338. static void log_bmf(s,r) char *s,*r;
  339. {
  340.   log_deny("Bad MAIL FROM:", s, r);
  341. } 
  342.  
  343. static void log_ngw (char *s, char *r)
  344. {
  345.   log_deny ("Relayclient", s, r);
  346. }
  347.  
  348. static void log_helo()
  349. {
  350.   syslog (LOG_INFO, "Received: from %s (HELO %s)\n", remotehost, helohost.s);
  351. } 
  352.  
  353. #else /* not SYSLOGGING */
  354. #define log_brt(s,r)
  355. #define log_bmf(s,r)
  356. #define log_deny(m,f,t)
  357. #define log_helo()
  358. #endif /* not SYSLOGGING */
  359.  
  360. #ifdef MAILFROMDNS
  361. int badmxcheck(dom) char *dom;
  362. {
  363.   ipalloc checkip = {0};
  364.   int ret=0;
  365.   stralloc checkhost = {0};
  366.  
  367.   if (!*dom) return (DNS_HARD);
  368.   if (!stralloc_copys(&checkhost,dom)) return (DNS_SOFT);
  369.   
  370.   switch (dns_mxip(&checkip,&checkhost,1))
  371.   {
  372.     case DNS_MEM:
  373.     case DNS_SOFT:
  374.          ret=DNS_SOFT;
  375.          break;
  376.          
  377.     case DNS_HARD: 
  378.          ret=DNS_HARD; 
  379.          break;
  380.     case 1:
  381.          if (checkip.len <= 0) ret=DNS_HARD; 
  382.          break;
  383.   }
  384.  
  385.   return (ret);
  386. }
  387. #endif
  388.  
  389. int addrallowed()
  390. {
  391.  int j;
  392.  if (!rhok) return 1;
  393.  j = byte_rchr(addr.s,addr.len,'@');
  394. #ifdef BADRCPT
  395.  if (brtok)
  396.     if (constmap(&mapbadrcptto, addr.s, addr.len - 1) ||
  397.         constmap(&mapbadrcptto, addr.s + j, addr.len - j - 1))
  398.        {log_brt(mailfrom.s,addr.s); return 0;}
  399. #endif
  400.  if (j >= addr.len) return 1; /* can be taken care of by envnoathost */
  401.  if (constmap(&maprcpthosts,addr.s + j + 1,addr.len - j - 2)) return 1;
  402.  for (;j < addr.len;++j)
  403.    if (addr.s[j] == '.')
  404.      if (constmap(&maprcpthosts,addr.s + j,addr.len - j - 1)) return 1;
  405.  log_ngw (mailfrom.s, addr.s);
  406.  return 0;
  407. }
  408.  
  409. void bmfcheck()
  410. {
  411.  int j;
  412.  flagbarf = 0;
  413.  if (!bmfok) return;
  414.  if (constmap(&mapbmf,addr.s,addr.len - 1)) { flagbarf = 1; return; }
  415.  j = byte_rchr(addr.s,addr.len,'@');
  416.  if (j < addr.len)
  417. #ifdef DENYSPAM 
  418.  {
  419. #endif
  420.    if (constmap(&mapbmf,addr.s + j,addr.len - j - 1)) { flagbarf = 1; return; }
  421. #ifdef DENYSPAM 
  422.    /* allow for bulkemailer@ checking */
  423.    if (constmap(&mapbmf,addr.s, j + 1)) { flagbarf = 1; return; }
  424.  }  
  425. #endif
  426. }
  427.  
  428. void smtp_greet(code) char *code; {
  429.  if (substdio_puts(&ssout,code) == -1) die();
  430.  if (substdio_put(&ssout,greeting.s,greeting.len) == -1) die(); }
  431. void smtp_quit() { smtp_greet("221 "); out("\r\n"); die(); }
  432. void smtp_help() { out("214-qmail home page: http://pobox.com/~djb/qmail.html\r\n214 send comments to qmail@pobox.com\r\n"); }
  433. void err_syntax() { out("555 syntax error (#5.5.4)\r\n"); }
  434. /* zzz 
  435.  void err_bmf() { out("553 sorry, your envelope sender is in my badmailfrom list (#5.7.1)\r\n"); }
  436. */
  437. void err_bmf() { out("553 syntax error, please forward to your postmaster (#5.7.1)\r\n"); }
  438. void err_dns() { out("451 DNS temporary failure (#4.3.0)\r\n"); }
  439. void err_nogateway() { out("553 sorry, that domain isn't in my list of allowed rcpthosts (#5.7.1)\r\n"); }
  440. void err_unimpl() { out("502 unimplemented (#5.5.1)\r\n"); }
  441. void err_seenmail() { out("503 one MAIL per message (#5.5.1)\r\n"); }
  442. void err_wantmail() { out("503 MAIL first (#5.5.1)\r\n"); }
  443. void err_wantrcpt() { out("503 RCPT first (#5.5.1)\r\n"); }
  444. void err_noop() { out("250 ok\r\n"); }
  445. void err_vrfy() { out("252 send some mail, i'll try my best\r\n"); }
  446. void err_qqt() { out("451 qqt failure (#4.3.0)\r\n"); }
  447. void smtp_helo(arg) char *arg; {
  448.  smtp_greet("250-"); out("\r\n250-PIPELINING\r\n250 8BITMIME\r\n");
  449.  seenmail = 0;
  450.  dohelo(arg ? arg : ""); }
  451. void smtp_rset() {
  452.  seenmail = 0;
  453.  out("250 flushed\r\n"); }
  454. void smtp_mail(arg) char *arg; {
  455. int i,j; char *why;
  456.  if (seenmail) { err_seenmail(); return; }
  457.  if (!arg) { err_syntax(); return; }
  458.  if (!addrparse(arg)) { err_syntax(); return; }
  459.  bmfcheck();
  460.  if (flagbarf) { log_bmf(addr.s,""); err_bmf(); return; }
  461. #ifdef DENYSPAM
  462. /************
  463.    DENYMAIL is set for this session from this client, 
  464.              so heavy checking of mailfrom
  465.    SPAM     -> refuse all mail
  466.    NOBOUNCE -> refuse null mailfrom
  467.    DNSCHECK -> validate Mailfrom domain
  468. ************/
  469.  
  470.  if (denymail)
  471.  {
  472.     why = denymail;
  473.     
  474.     if (!str_diff("SPAM", denymail)) 
  475.        flagbarf=1;
  476.     else
  477.       if (!addr.s[0] || !str_diff("#@[]", addr.s)) /*mjr*/
  478.      /* if (!addr.s[0]) */
  479.       {  
  480.          if (!str_diff("NOBOUNCE", denymail)) 
  481.             flagbarf=1;
  482.       }
  483. #ifdef MAILFROMCHECK
  484.       else
  485.       {
  486.         /*why = "Invalid.Mailfrom";*/
  487.         why = "MAIL FROM: syntax";
  488.         if ((i=byte_chr(addr.s,addr.len,'@')) >= addr.len)
  489.            flagbarf=1;       /* no '@' in from */
  490.         else
  491.         {
  492.           /* money!@domain.TLD */
  493.           if (addr.s[i-1] == '!') 
  494.              flagbarf=1;
  495.              
  496.           /* check syntax, visual */
  497.           if ((j = byte_rchr(addr.s+i, addr.len-i, '.')) >= addr.len-i)
  498.              flagbarf=1;  /* curious no '.' in domain.TLD */
  499.          
  500.           j = addr.len-(i+1+j+1);
  501.           if (j < 2 || j > 3)
  502.              flagbarf=1;  /* root domain, not a country (2), nor TLD (3)*/
  503.  
  504. #ifdef MAILFROMDNS
  505.          if (!flagbarf)
  506.           if (!str_diff("DNSCHECK", denymail)) 
  507.           {
  508.            /* check syntax, via DNS */
  509.              why = "MAIL FROM: DNS";
  510.              switch (badmxcheck(&addr.s[i+1]))
  511.              {
  512.                case 0:         break; /*valid*/
  513.                case DNS_SOFT:    flagbarf=2; /*fail tmp*/
  514.                                 why = "(temporary) MAIL FROM: DNS";
  515.                                 break;
  516.                case DNS_HARD:     flagbarf=1; 
  517.                            break;
  518.              }
  519.           }
  520. #endif
  521.         }
  522.       }
  523. #endif
  524.  
  525.     if (flagbarf)    
  526.     {
  527.       log_deny(why, addr.s, ""); 
  528.       if (2==flagbarf)
  529.          err_dns(); 
  530.       else
  531.          err_bmf();
  532.       return;
  533.     }
  534.  }/* denymail */
  535. #endif   
  536.  seenmail = 1; out("250 ok\r\n");
  537.  if (!stralloc_copys(&rcptto,"")) outofmem();
  538.  if (!stralloc_copys(&mailfrom,addr.s)) outofmem();
  539.  if (!stralloc_0(&mailfrom)) outofmem(); }
  540. void smtp_rcpt(arg) char *arg; {
  541.  if (!seenmail) { err_wantmail(); return; }
  542.  if (!arg) { err_syntax(); return; }
  543.  if (!addrparse(arg)) { err_syntax(); return; }
  544.  if (relayclient)
  545.   {
  546.    --addr.len;
  547.    if (!stralloc_cats(&addr,relayclient)) outofmem();
  548.    if (!stralloc_0(&addr)) outofmem();
  549.   }
  550.  else
  551.    if (!addrallowed()) { err_nogateway(); return; }
  552.  out("250 ok\r\n");
  553.  if (!stralloc_cats(&rcptto,"T")) outofmem();
  554.  if (!stralloc_cats(&rcptto,addr.s)) outofmem();
  555.  if (!stralloc_0(&rcptto)) outofmem(); 
  556. }
  557.  
  558. char accept_buf[FMT_ULONG];
  559. void acceptmessage(qp) unsigned long qp;
  560. {
  561.  datetime_sec when;
  562.  when = now();
  563.  out("250 ok ");
  564.  accept_buf[fmt_ulong(accept_buf,(unsigned long) when)] = 0;
  565.  out(accept_buf);
  566.  out(" qp ");
  567.  accept_buf[fmt_ulong(accept_buf,qp)] = 0;
  568.  out(accept_buf);
  569.  out("\r\n");
  570. }
  571.  
  572. void smtp_data() {
  573.  int hops; int r; unsigned long qp;
  574.  if (!seenmail) { err_wantmail(); return; }
  575.  if (!rcptto.len) { err_wantrcpt(); return; }
  576.  seenmail = 0;
  577.  if (qmail_open(&qqt) == -1) { err_qqt(); return; }
  578.  qp = qmail_qp(&qqt);
  579.  out("354 go ahead\r\n");
  580.  
  581.  received(&qqt,"SMTP",local,remoteip,remotehost,remoteinfo,(r=case_diffs(remotehost,helohost.s)) ? helohost.s : 0);
  582.  if (r) log_helo();
  583.  blast(&ssin,&hops);
  584.  hops = (hops >= MAXHOPS);
  585.  if (hops) qmail_fail(&qqt);
  586.  qmail_from(&qqt,mailfrom.s);
  587.  qmail_put(&qqt,rcptto.s,rcptto.len);
  588.  
  589.  r = qmail_close(&qqt);
  590.  if (!r) { acceptmessage(qp); return; }
  591.  if (hops) { out("554 too many hops, this message is looping (#5.4.6)\r\n"); return; }
  592.  switch(r)
  593.   {
  594.    case QMAIL_TOOLONG: out("554 address too long (#5.1.3)\r\n"); return;
  595.    case QMAIL_SYS: out("451 qq system error (#4.3.0)\r\n"); return;
  596.    case QMAIL_READ: out("451 qq read error (#4.3.0)\r\n"); return;
  597.    case QMAIL_WRITE: out("451 qq write error or disk full (#4.3.0)\r\n"); return;
  598.    case QMAIL_NOMEM: out("451 qq out of memory (#4.3.0)\r\n"); return;
  599.    case QMAIL_EXECSOFT: out("451 could not exec qq (#4.3.0)\r\n"); return;
  600.    case QMAIL_TIMEOUT: out("451 qq timeout (#4.3.0)\r\n"); return;
  601.    case QMAIL_WAITPID: out("451 qq waitpid surprise (#4.3.0)\r\n"); return;
  602.    case QMAIL_CRASHED: out("451 qq crashed (#4.3.0)\r\n"); return;
  603.    case QMAIL_USAGE: out("451 qq usage surprise (#4.3.0)\r\n"); return;
  604.    default: out("451 qq internal bug (#4.3.0)\r\n"); return;
  605.   }
  606. }
  607.  
  608. static struct { void (*fun)(); char *text; int flagflush; } smtpcmd[] = {
  609.   { smtp_rcpt, "rcpt", 0 }
  610. , { smtp_mail, "mail", 0 }
  611. , { smtp_data, "data", 1 }
  612. , { smtp_quit, "quit", 1 }
  613. , { smtp_helo, "helo", 1 }
  614. , { smtp_helo, "ehlo", 1 }
  615. , { smtp_rset, "rset", 0 }
  616. , { smtp_help, "help", 1 }
  617. , { err_noop, "noop", 1 }
  618. , { err_vrfy, "vrfy", 1 }
  619. , { 0, 0, 0 }
  620. };
  621.  
  622. void doit(cmd)
  623. char *cmd;
  624. {
  625.  int i;
  626.  int j;
  627.  char ch;
  628.  
  629.  for (i = 0;smtpcmd[i].fun;++i)
  630.   {
  631.    for (j = 0;ch = smtpcmd[i].text[j];++j)
  632.      if ((cmd[j] != ch) && (cmd[j] != ch - 32))
  633.        break;
  634.    if (!ch)
  635.      if (!cmd[j] || (cmd[j] == ' '))
  636.       {
  637.        while (cmd[j] == ' ') ++j;
  638.        if (!cmd[j])
  639.          smtpcmd[i].fun((char *) 0);
  640.        else
  641.          smtpcmd[i].fun(cmd + j);
  642.        if (smtpcmd[i].flagflush) flush();
  643.        return;
  644.       }
  645.   }
  646.  err_unimpl();
  647.  flush();
  648. }
  649.  
  650. void getcontrols()
  651. {
  652.  if (control_init() == -1) die();
  653.  if (control_rldef(&greeting,"control/smtpgreeting",1,(char *) 0) != 1) die();
  654.  switch(control_rldef(&liphost,"control/localiphost",1,(char *) 0))
  655.   { case -1: die(); case 1: liphostok = 1; }
  656.  if (control_readint(&timeout,"control/timeoutsmtpd") == -1) die();
  657.  if (timeout <= 0) timeout = 1;
  658.  switch(control_readfile(&rcpthosts,"control/rcpthosts",0))
  659.   {
  660.    case -1: die();
  661.    case 1:
  662.      rhok = 1;
  663.      if (!constmap_init(&maprcpthosts,rcpthosts.s,rcpthosts.len,0)) die();
  664.   }
  665.  switch(control_readfile(&bmf,"control/badmailfrom",0))
  666.   {
  667.    case -1: die();
  668.    case 1:
  669.      bmfok = 1;
  670.      if (!constmap_init(&mapbmf,bmf.s,bmf.len,0)) die();
  671.   }
  672. #ifdef BADRCPT
  673.  switch(control_readfile(&brt,"control/badrcptto",0))
  674.   {
  675.    case -1: die();
  676.    case 1:
  677.      brtok = 1;
  678.      if (!constmap_init(&mapbadrcptto,brt.s,brt.len,0)) die();
  679.   }
  680. #endif
  681. }
  682.  
  683. void main()
  684. {
  685.  static stralloc cmd = {0};
  686.  int match;
  687.  
  688.  sig_alarmcatch(sigalrm);
  689.  sig_pipeignore();
  690.  
  691. #ifdef SYSLOGGING
  692.   openlog ("qmail-smtpd", 0, LOG_MAIL);
  693. #endif
  694.  
  695.  if (chdir(auto_qmail) == -1)
  696.  {
  697. #ifdef SYSLOGGING
  698.    syslog (LOG_ERR, "Unable to switch to home directory (%s): errno=%m",
  699.            auto_qmail);
  700. #endif
  701.    die();
  702.  }
  703.  getcontrols();
  704.  getenvs();
  705.  
  706.  if (ipme_init() != 1) die();
  707.  
  708.  smtp_greet("220 ");
  709.  out(" ESMTP\r\n");
  710.  
  711.  for (;;)
  712.   {
  713.    /* XXX: recipient can contain quoted lf. aargh. */
  714.    if (getln(&ssin,&cmd,&match,'\n') == -1) die();
  715.    if (!match) die();
  716.    if (cmd.len == 0) die();
  717.    if (cmd.s[--cmd.len] != '\n') die();
  718.    if ((cmd.len > 0) && (cmd.s[cmd.len - 1] == '\r')) --cmd.len;
  719.    cmd.s[cmd.len++] = 0;
  720.    doit(cmd.s);
  721.   }
  722. #ifdef SYSLOGGING
  723.   closelog ();
  724. #endif
  725. }
  726.